package io.confluent.kafka.consumer.controller;

import io.confluent.kafka.consumer.conf.PropertiesReader;
import io.confluent.kafka.consumer.core.ConsumerPerformance;


/**
 * Created by taotao on 2017/12/18.
 */
public class PmAlarmControler {
    public static void main(String[] args) {
        String topics = PropertiesReader.KAFKA_CONSUMER_TOPICS_PERFORMACE;
        ConsumerPerformance consumerPerformance = new ConsumerPerformance(topics);
        consumerPerformance.start();
    }
}
